package com.hibase.core.mq.component;

/**
 * @author chenfeng
 * @version 1.0
 * @date 2021/7/23 13:46
 * @des https://gitee.com/cheershi
 */
public interface HibaseQueueUtil {
    /**
     * 添加到队列中  默认尾插
     * @param topic 主题
     * @param msg 消息
     */
    void offer(String topic, Object msg);

    /**
     * 添加到队列中
     * @param beFirst 是否头插
     * @param topic 主题
     * @param msg 消息
     */
    void offer(Boolean beFirst,String topic, Object msg);
}
